e7011d78a3019880a4e00ab5f697c3cfd20161bb,flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java,JobManagerRunner,grantLeadership,#UUID#,348
Before Change
onFatalError(new Exception("Could not start the job manager.", e));
}
} else {
log.info("Job {} ({}) already finished by others.", jobGraph.getName(), jobGraph.getJobID());
jobFinishedByOther();
}
}
After Change
return;
}
} catch (Throwable t) {
log.error("Could not access status (running/finished) of job {}. ", jobGraph.getJobID(), t);
onFatalError(t);
return;
}